package study.core.acc

import org.apache.spark.{SparkConf, SparkContext}

/**
 * 不使用累加器的情况
 *
 * @author zh
 * @date 2021/5/18 11:12
 */
object TestNoAcc {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setMaster("local").setAppName("WordCount")
    // 建立Spark连接
    val sc = new SparkContext(sparkConf)

    val rdd = sc.makeRDD(List(1, 2, 3, 4))

    var sum = 0
    rdd.foreach(
      num => {
        println("加上数字"+num)
        sum += num
        println("累加为"+sum)
      }
    )
    println("累加结束，最终结果"+sum)
  }
}
